package com.jiaying.sync;

/**
 * Kafka配置测试类
 * 用于验证Kafka集群配置是否正确加载
 */
public class KafkaConfigTest {
    
    /**
     * 主方法 - 测试Kafka配置
     */
    public static void main(String[] args) {
        System.out.println("Kafka配置测试");
        System.out.println("=============");
        
        // 创建Kafka监听器实例以测试配置
        KafkaListener listener = new KafkaListener();
        
        System.out.println("Kafka监听器创建成功，配置已正确加载。");
        System.out.println("程序将在5秒后退出。");
        
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        
        // 停止监听器
        listener.stopListening();
        
        System.out.println("测试完成。");
    }
}